//package com.example.config;
//
//import javax.websocket.Session;
//import java.io.IOException;
//import java.util.Map;
//import java.util.concurrent.ConcurrentHashMap;
//
//
////连接池
//
//public class SessionPool {
//
//
////    连接的人
//
//    public static Map<String, Session> sessions = new ConcurrentHashMap<>();
//
//    public static void close(String sessionId) throws IOException {
//
//        for (String userId : SessionPool.sessions.keySet()) {
//            Session session = SessionPool.sessions.get(userId);
//            if (session.getId().equals(sessionId)) {
//                sessions.remove(userId);
//                break;
//            }
//        }
//    }
//
//    public static void sendMessage(String sessionId, String message) {
//        sessions.get(sessionId).getAsyncRemote().sendText(message);
//    }
//
//    public static void sendMessage(String message) {
//
////        消息群发
//        for (String sessionId : SessionPool.sessions.keySet()) {
//            System.out.println(1);
//            SessionPool.sessions.get(sessionId).getAsyncRemote().sendText(message);
//        }
//
//    }
//
//
//}
